package org.tao.lightningmq.client.consumer;

import org.tao.lightningmq.common.dto.ConsumeMsgCommitLogDTO;

/**
 * @Author lht
 * @date 2025/1/19 - 19:31
 * @description:
 */
public class ConsumeMessage {

    private int queueId;

    private ConsumeMsgCommitLogDTO consumeMsgCommitLogDTO;

    public int getQueueId() {
        return queueId;
    }

    public void setQueueId(int queueId) {
        this.queueId = queueId;
    }

    public ConsumeMsgCommitLogDTO getConsumeMsgCommitLogDTO() {
        return consumeMsgCommitLogDTO;
    }

    public void setConsumeMsgCommitLogDTO(ConsumeMsgCommitLogDTO consumeMsgCommitLogDTO) {
        this.consumeMsgCommitLogDTO = consumeMsgCommitLogDTO;
    }

}
